package cn.gemiman.daoyi.module.iot.controller.admin.kafkamsglogs.vo;

import io.swagger.v3.oas.annotations.media.Schema;
import jakarta.validation.constraints.NotNull;
import lombok.Data;

@Schema(description = "管理后台 - kafka原始消息新增/修改 Request VO")
@Data
public class KafkaMsgLogsSaveReqVO {

    @Schema(description = "编号", requiredMode = Schema.RequiredMode.REQUIRED, example = "29593")
    private Long id;

    @Schema(description = "主题")
    private String topics;

    @Schema(description = "生产者")
    private String bootstrapServers;

    @Schema(description = "消费者", example = "20994")
    private String consumerGroupId;

    @Schema(description = "原始消息")
    private String msg;

    @Schema(description = "是否已读", requiredMode = Schema.RequiredMode.REQUIRED)
    @NotNull(message = "是否已读不能为空")
    private Boolean viewed;

}
